package com.atguigu.sparkcore.rdd.file.`object`

import com.atguigu.sparkcore.util.MySparkContextUtil

/**
 * description ：读取Object文件
 * author ：剧情再美终是戏
 * mail : 13286520398@163.com
 * date ：Created in 2020/1/8 21:15
 * modified By ：
 * version: : 1.0
 */
object RObjectFile {

  def main(args: Array[String]): Unit = {

    // 创建sparkContext
    val sc = MySparkContextUtil.get(args)

    // 读取Object文件为rdd
    val rdd = sc.objectFile("c:/outputobj")

    // 输出rdd
    rdd.foreach(println)

    // 关闭sparkContext资源
    MySparkContextUtil.close(sc)
  }

}
